package com.deep.flink.demo.function;

import org.apache.flink.table.annotation.DataTypeHint;
import org.apache.flink.table.annotation.FunctionHint;
import org.apache.flink.table.functions.TableFunction;
import org.apache.flink.types.Row;

/**
 */
@FunctionHint(output = @DataTypeHint("ROW<w STRING, len INT >"))
public class JoinFunction extends TableFunction<Row> {

    public void eval(String loginName) {
        collect(Row.of(loginName, loginName.length()));
    }
}
